Spring Cloud 开发实战

@Configuration
public class ShopcartBeanConfig {

	@LoadBalanced (1)
	@Bean
	public RestTemplate restTemplate() {
		return new RestTemplate();
	}

}

@Slf4j
@RestController
@RequestMapping("/shopcart/item")
public class ShopcartController {

	@Autowired
	private RestTemplate restTemplate;

	/**
	 * 将商品加入购物车，创建购物车项
	 *
	 * @author zhailiang@zkh360.com 2018年6月1日
	 * @param id
	 *            商品id
	 * @return
	 */
	@PostMapping
	public void create(Long productId) {

		String url = "http://commodity-service/products/" + productId; (1)
		ProductInfo info = restTemplate.getForObject(url, ProductInfo.class); (2)

		log.info(info.getName());
	}

}

<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-feign</artifactId>
</dependency>

@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients (1)
public class ShopcartApplication {

	/**
	 *
	 * @author zhailiang@zkh360.com
	 * 2018年6月1日
	 * @param args
	 */
	public static void main(String[] args) {
		SpringApplication.run(ShopcartApplication.class, args);
	}

}

@FeignClient("commodity-service") (1)
public interface ProductClient {

	@GetMapping("/products/{id}")
	ProductInfo getInfo(@PathVariable("id") Long id); (2)

}

@Slf4j
@RestController
@RequestMapping("/shopcart/item")
public class ShopcartController {

//	@Autowired
//	private RestTemplate restTemplate;

	@Autowired
	private ProductClient productClient; (1)

	/**
	 * 将商品加入购物车，创建购物车项
	 *
	 * @author zhailiang@zkh360.com 2018年6月1日
	 * @param id
	 *            商品id
	 * @return
	 */
	@PostMapping
	public void create(Long productId) {

//		String url = "http://commodity-service/product/" + productId;
//		ProductInfo info = restTemplate.getForObject(url, ProductInfo.class);

		ProductInfo info = productClient.getInfo(productId); (2)

		log.info(info.getName());


	}

}

spring:
  cloud:
    stream:
      binders:
        rabbit:
          type: rabbit
          environment:
            spring:
              rabbitmq:
                addresses: amqp://127.0.0.1:5672
                username: sa
                password: 123456
      bindings:
        foo:
          binder: rabbit
          destination: test
          content-type: application/json
          group: shopcart
          consumer:
            concurrency: 2 (1)

public final class Constants {

	public static final String rabbit_addresses = "mq.dev.zkh360.com:50017";           (1)
	public static final String rabbit_username = "zkhdev";                             (2)
	public static final String rabbit_password = "zkhdev";                             (3)
	public static final String rabbit_virtual_host = "/";                              (4)

	public static final String rabbit_exchangename = "exchange_first_meaasge";         (5)
	public static final boolean rabbit_exchangedurable = true;                         (6)
	public static final boolean rabbit_exchangeautodelete = true;                      (7)
	public static final boolean rabbit_ignoreDeclarationExceptions = true;             (8)
	public static final String rabbit_queuename = "queue_first_message";               (9)
	public static final boolean rabbit_queuedurable = true;                            (10)
	public static final String rabbit_routingkey = "routing.first.# ";                 (11)
	public static final String rabbit_key = "routing.first.message";                   (12)

}

@Configuration
@ComponentScan({"com.bfxy.spring.*"})
public class RabbitMQConfig {

	@Bean
	public ConnectionFactory connectionFactory(){                                           (1)
		CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
		connectionFactory.setAddresses(Constants.rabbit_addresses);
		connectionFactory.setUsername(Constants.rabbit_username);
		connectionFactory.setPassword(Constants.rabbit_password);
		connectionFactory.setVirtualHost(Constants.rabbit_virtual_host);
		return connectionFactory;
	}

	@Bean
	public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory) {                   (2)
		RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory);
		rabbitAdmin.setAutoStartup(true);
		return rabbitAdmin;
	}

    @Bean
	public TopicExchange firstExchange() {                                                  (3)
		Map<String, Object> arguments = new HashMap<String, Object>();
		arguments.put("ignoreDeclarationExceptions", Constants.rabbit_ignoreDeclarationExceptions);
		return new TopicExchange(Constants.rabbit_exchangename, Constants.rabbit_exchangedurable,
				Constants.rabbit_exchangeautodelete, arguments);
	}

    @Bean
	public Queue firstQueue() {                                                             (4)
		return new Queue(Constants.rabbit_queuename, Constants.rabbit_queuedurable);
	}

    @Bean
    public Binding firstBinding() {                                                         (5)
        return BindingBuilder.bind(firstQueue()).to(firstExchange()).with(Constants.rabbit_routingkey);
    }

}

@Component
 public class ProducerMessage {

	@Autowired
	private RabbitAdmin rabbitAdmin;

	@Autowired
	private Binding firstBinding;

    @Autowired
	private UpDownStream upDownStream;

	/**
	 * 声明交换机，队列及建立关联
	 */

     rabbitAdmin.declareBinding(firstBinding);                                           (1)

/**
	 *
	 * 消费端发送消息
	 * @param message              发送的消息
	 * @param exchangename         自定义交换机名称
	 * @param routingname          自定义路由名称
	 * @return                     消息id
	 */


	String messageid = upDownStream.upSeMessage(message,exchangename,routingname);      (2)

}

public final class Constants {

	public static final String rabbit_addresses = "mq.dev.zkh360.com:50017";           (1)
	public static final String rabbit_username = "zkhdev";                             (2)
	public static final String rabbit_password = "zkhdev";                             (3)
	public static final String rabbit_virtual_host = "/";                              (4)

	public static final String rabbit_exchangename = "exchange_first_meaasge";         (5)
	public static final boolean rabbit_exchangedurable = true;                         (6)
	public static final boolean rabbit_exchangeautodelete = true;                      (7)
	public static final boolean rabbit_ignoreDeclarationExceptions = true;             (8)
	public static final String rabbit_queuename = "queue_first_message";               (9)
	public static final boolean rabbit_queuedurable = true;                            (10)
	public static final String rabbit_routingkey = "routing.first.# ";                 (11)

}

@Configuration
@ComponentScan({"com.bfxy.spring.*"})
public class RabbitMQConfig {

	@Bean
	public ConnectionFactory connectionFactory(){                                           (1)
		CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
		connectionFactory.setAddresses(Constants.rabbit_addresses);
		connectionFactory.setUsername(Constants.rabbit_username);
		connectionFactory.setPassword(Constants.rabbit_password);
		connectionFactory.setVirtualHost(Constants.rabbit_virtual_host);
		return connectionFactory;
	}

	@Bean
	public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory) {                   (2)
		RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory);
		rabbitAdmin.setAutoStartup(true);
		return rabbitAdmin;
	}

    @Bean
	public TopicExchange firstExchange() {                                                  (3)
		Map<String, Object> arguments = new HashMap<String, Object>();
		arguments.put("ignoreDeclarationExceptions", Constants.rabbit_ignoreDeclarationExceptions);
		return new TopicExchange(Constants.rabbit_exchangename, Constants.rabbit_exchangedurable,
				Constants.rabbit_exchangeautodelete, arguments);
	}

    @Bean
	public Queue firstQueue() {                                                             (4)
		return new Queue(Constants.rabbit_queuename, Constants.rabbit_queuedurable);
	}

    @Bean
    public Binding firstBinding() {                                                         (5)
        return BindingBuilder.bind(firstQueue()).to(firstExchange()).with(Constants.rabbit_routingkey);
    }

}

@Component
 public class ConsumerMessage {

	@Autowired
	private RabbitAdmin rabbitAdmin;

	@Autowired
	private Binding firstBinding;


	/**
	 * 声明交换机，队列及建立关联
	 */

     rabbitAdmin.declareBinding(firstBinding);                                                                              (1)

/**
	 * callbackservice consumer message
	 * @param message
	 * @param channel
	 * @param headers
	 * @return
	 * @throws Exception
	 */

	@RabbitListener(bindings = @QueueBinding(
			value = @Queue(value = "${spring.rabbitmq.listener.first.queue.name}",                                          (2)
			durable="true"),
			exchange = @Exchange(value = "${spring.rabbitmq.listener.first.exchange.name}",                                 (3)
			durable="true",
			type= "topic",
			ignoreDeclarationExceptions = "true"),
			key = "${spring.rabbitmq.listener.first.key}"                                                                   (4)
			)
	)
	@RabbitHandler
	public void consumerMessage(Message message,Channel channel) throws Exception {
		// TODO                                                                                                             (5)
	}

}

<dependency>
	    <groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
		<groupId>com.alibaba</groupId>
		<artifactId>fastjson</artifactId>
		<version>1.1.26</version>
</dependency>
<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-aop</artifactId>
</dependency>

server.servlet.context-path=/
server.port=8090
spring.rabbitmq.addresses=mq.dev.zkh360.com:50017                              (1)
#spring.rabbitmq.host=mq.dev.zkh360.com                                        (2)
#spring.rabbitmq.port=50017                                                    (3)
spring.rabbitmq.username=zkhdev                                                (4)
spring.rabbitmq.password=zkhdev                                                (5)
spring.rabbitmq.virtual-host=/                                                 (6)
spring.rabbitmq.connection-timeout=15000                                       (7)
spring.rabbitmq.template.retry.enabled=true                                    (8)
spring.rabbitmq.template.retry.initial-interval=2s                             (9)

#producer                                                                      (10)
spring.rabbitmq.publisher-confirms=true                                        (11)
spring.rabbitmq.publisher-returns=true                                         (12)
spring.rabbitmq.template.mandatory=true                                        (13)

#consumer                                                                      (14)
spring.rabbitmq.listener.retry.enabled=true                                    (15)
spring.rabbitmq.listener.simple.acknowledge-mode=manual                        (16)
spring.rabbitmq.listener.simple.concurrency=5                                  (17)
spring.rabbitmq.listener.simple.max-concurrency=10                             (18)

#second send message                                                           (19)
spring.rabbitmq.listener.second.exchange.name=exchange_second_meaasge          (20)
spring.rabbitmq.listener.second.exchange.durable=true                          (21)
spring.rabbitmq.listener.second.exchange.type=topic                            (22)
spring.rabbitmq.listener.second.exchange.ignoreDeclarationExceptions=true      (23)
spring.rabbitmq.listener.second.routingkey=routing.second.#                    (24)
spring.rabbitmq.listener.second.key=routing.second.message                     (25)
spring.rabbitmq.listener.second.queue.name=queue_second_message                (26)
spring.rabbitmq.listener.second.queue.durable=true                             (27)
spring.rabbitmq.listener.second.queue.ttl=600000                               (28)

#second send message to dxl meaasge                                            (29)
spring.rabbitmq.listener.dxl.exchange.name=exchange_dxl_meaasge                (30)
spring.rabbitmq.listener.dxl.exchange.durable=true                             (31)
spring.rabbitmq.listener.dxl.exchange.type=fanout                              (32)
spring.rabbitmq.listener.dxl.exchange.ignoreDeclarationExceptions=true         (33)
spring.rabbitmq.listener.dxl.queue.name=queue_dxl_message                      (34)
spring.rabbitmq.listener.dxl.queue.durable=true                                (35)

#consumer send confim message                                                  (36)
spring.rabbitmq.listener.confim.exchange.name=exchange_confim_meaasge          (37)
spring.rabbitmq.listener.confim.exchange.durable=true                          (38)
spring.rabbitmq.listener.confim.exchange.type=topic                            (39)
spring.rabbitmq.listener.confim.exchange.ignoreDeclarationExceptions=true      (40)
spring.rabbitmq.listener.confim.routingkey=routing.confim.#                    (41)
spring.rabbitmq.listener.confim.key=routing.confim.message                     (42)
spring.rabbitmq.listener.confim.queue.name=queue_confim_message                (43)
spring.rabbitmq.listener.confim.queue.durable=true                             (44)

@Configuration
@ComponentScan({"com.barry.springboot.*"})
public class MainConfig {

}

@Component
public class UpDownStream {

	@Autowired
	private RabbitTemplate rabbitTemplate;


	@Value("${spring.rabbitmq.listener.second.exchange.name}")
	private String secondexchange;
	@Value("${spring.rabbitmq.listener.second.routingkey}")
	private String secondroutingKey;
	@Value("${spring.rabbitmq.listener.confim.exchange.name}")
	private String confimexchange;
	@Value("${spring.rabbitmq.listener.confim.routingkey}")
	private String confimroutingKey;
	@Value("${spring.rabbitmq.listener.confim.exchange.name}")

	/**
	 *
	 * 生产端发送消息方法
	 * @param message              发送的消息
	 * @param exchangename         自定义交换机名称
	 * @param routingname          自定义路由名称
	 * @return                     消息id
	 */
	public String upSeMessage(Object message,String exchangename,String routingname) {
		String messageid = UUID.randomUUID().toString().replaceAll("-", "").toLowerCase();
		Map<String, Object> properties = new HashMap<String, Object>();
		properties.put("messageid", messageid);
		properties.put("exchangename", exchangename);
		properties.put("routingname", routingname);
		MessageHeaders messageHeaders = new MessageHeaders(properties);                              (1)
		Message msg = MessageBuilder.createMessage(ordermessage, messageHeaders);                    (2)
		CorrelationData cd = new CorrelationData(messageid);                                         (3)
		rabbitTemplate.convertAndSend(exchangename, routingname, msg, cd);                           (4)
		rabbitTemplate.convertAndSend(secondexchange, secondroutingKey, msg, cd);                    (5)
	}



	/**
	 * 中间服务消费消费端确认消息
	 * @param message
	 * @param channel
	 * @param headers
	 * @return
	 * @throws Exception
	 */

	@RabbitListener(bindings = @QueueBinding(
			value = @Queue(value = "${spring.rabbitmq.listener.confim.queue.name}",
			durable="${spring.rabbitmq.listener.confim.queue.durable}"),
			exchange = @Exchange(value = "${spring.rabbitmq.listener.confim.exchange.name}",
			durable="${spring.rabbitmq.listener.first.exchange.durable}",
			type= "${spring.rabbitmq.listener.first.exchange.type}",
			ignoreDeclarationExceptions = "${spring.rabbitmq.listener.first.exchange.ignoreDeclarationExceptions}"),
			key = "${spring.rabbitmq.listener.first.key}"
			)
	)
	@RabbitHandler
	public void callBackConsumerMessage(@Payload Message message,
			Channel channel,
			@Headers Map<String, Object> headers) throws Exception {
		System.err.println("---------------callbackservice-----------------------");

		String msg = message.getPayload().toString();
		String messageid = (String) message.getHeaders().get("messageid");
		int type = Integer.parseInt(messageid)%8;
		// TODO 根据type将messageid，msg保存至业务数据库中                                           (6)
		Long deliveryTag = (Long)headers.get(AmqpHeaders.DELIVERY_TAG);
		//手工ACK
		channel.basicAck(deliveryTag, false);                                                        (7)

	}

	/**
	 * 中间服务消费生产端二次发送的确认消息
	 * @param message
	 * @param channel
	 * @param headers
	 * @return
	 * @throws Exception
	 */

	@RabbitListener(bindings = @QueueBinding(
			value = @Queue(value = "${spring.rabbitmq.listener.dxl.queue.name}",
			durable="${spring.rabbitmq.listener.dxl.queue.durable}"),
			exchange = @Exchange(value = "${spring.rabbitmq.listener.dxl.exchange.name}",
			durable="${spring.rabbitmq.listener.dxl.exchange.durable}",
			type= "fanout",
			ignoreDeclarationExceptions = "${spring.rabbitmq.listener.dxl.exchange.ignoreDeclarationExceptions}")
			)
	)
	@RabbitHandler
	public void callBackDelayMessage(@Payload Message message,
			Channel channel,
			@Headers Map<String, Object> headers) throws Exception {
		System.err.println("---------------callbackservice-----------------------");
		// TODO 监听到生产端二次发送的消息与msg DB中数据比较（使用messageid）
		String messageid = (String) message.getHeaders().get("messageid");                          (8)
		// 如数据库中无数据则调用upSeMessage发送数据
		String newMsgid = UUID.randomUUID().toString().replaceAll("-", "").toLowerCase();
		CorrelationData cd = new CorrelationData(newMsgid);
		message.getHeaders().put("messageid", newMsgid);                                            (9)
		String exchangename = (String) message.getHeaders().get("exchangename");
		String routingname = (String) message.getHeaders().get("routingname");
		rabbitTemplate.convertAndSend(exchangename, routingname, message, cd);                      (10)
		rabbitTemplate.convertAndSend(secondexchange, secondroutingKey, message, cd);               (11)
		Long deliveryTag = (Long)headers.get(AmqpHeaders.DELIVERY_TAG);
		//手工ACK
		channel.basicAck(deliveryTag, false);                                                       (12)

	}

}

@Aspect
@Order(-99)
@Component
public class DownSendMessage {

	@Autowired
	private RabbitTemplate rabbitTemplate;

	private String confimexchange;
	@Value("${spring.rabbitmq.listener.confim.routingkey}")
	private String confimroutingKey;
	@Value("${spring.rabbitmq.listener.confim.exchange.name}")

	@After("@annotation(org.springframework.amqp.rabbit.annotation.RabbitListener)")
    public void sendConfirmMessage(JoinPoint point) {
       rabbitTemplate.convertAndSend(confimexchange, confimroutingKey, point.getArgs());             (1)
    }

}

public class ForkJoinSumCalculator extends RecursiveTask<Long> { (1)
	/**
	 *
	 */
	private static final long serialVersionUID = -4008111329500774405L;

	private final long[] numbers; (2)
	private final int start; (3)
	private final int end;

	private static final long LIMIT = 10000; (4)

	public ForkJoinSumCalculator(long[] numbers) { (5)
		this(numbers, 0, numbers.length);
	}

	private ForkJoinSumCalculator(long[] numbers, int start, int end) { (6)
		this.numbers = numbers;
		this.start = start;
		this.end = end;
	}

	@Override
	protected Long compute() { (7)
		int length = end - start; (8)
		if(length <= LIMIT) {
			return computeSum(); (9)
		}

		ForkJoinSumCalculator leftTask = new ForkJoinSumCalculator(numbers, start, start + length / 2); (10)
		leftTask.fork(); (11)

		ForkJoinSumCalculator rightTask = new ForkJoinSumCalculator(numbers, start + length / 2, end); (12)

		Long rightResult = rightTask.compute(); (13)
		Long leftResult = leftTask.join(); (14)

		return rightResult + leftResult; (15)
	}

	private Long computeSum() { (16)
		long sum = 0;
		for (int i = start; i < end; i++) {
			sum += numbers[i];

		}
		return sum;
	}

}

public class Main {

	public static void main(String[] args) {
		long[] numbers = LongStream.rangeClosed(0, 100000000).toArray(); (1)
		ForkJoinTask<Long> task = new ForkJoinSumCalculator(numbers); (2)
		long now = System.currentTimeMillis();
		System.out.println(new ForkJoinPool().invoke(task)); (3)
		System.out.println("耗时:" + (System.currentTimeMillis() - now));
	}

}

public static long sequenceSum(long n) {
	return Stream.iterate(1L, i -> i + 1)
			.limit(n)
			.reduce(0L, Long::sum);
}

public static long iterativeSum(long n) {
	long result = 0;
	for (int i = 1; i <= n; i++) {
		result += i;
	}
	return result;
}

public static long test(Function<Long, Long> computer, long n) { (1)
	long fastest = Long.MAX_VALUE;
	for (int i = 0; i < 10; i++) {
		long start = System.currentTimeMillis();
		computer.apply(n);
		long duration = System.currentTimeMillis() - start;
		if (duration < fastest) {
			fastest = duration;
		}
	}
	return fastest;
}

public static void main(String[] args) {
	long n = 20_000_000;
	System.out.println("顺序归纳耗时:"+test(SumComputer::sequenceSum, n));
	System.out.println("for循环归纳耗时:"+test(SumComputer::iterativeSum, n));
	System.out.println("并行归纳耗时:"+test(SumComputer::parallelSum, n));
}

public static long parallelSum(long n) {
	return LongStream.rangeClosed(0, n).parallel().reduce(0L, Long::sum);
}

public static long sequenceSum(long n) {
	return LongStream.rangeClosed(0, n).reduce(0L, Long::sum);
}

public static long wrongSum(long n) {
	Accumulator accumulator = new Accumulator();
	LongStream.rangeClosed(0, n).parallel().forEach(accumulator::add);
	return accumulator.total;
}

public class Accumulator {

	public long total = 0;

	public void add(long value) {
		total += value;
	}

}

public static long test(Function<Long, Long> computer, long n) {
		long fastest = Long.MAX_VALUE;
		for (int i = 0; i < 10; i++) {
			long start = System.currentTimeMillis();
			long sum = computer.apply(n);
			System.out.println("result is : "+ sum); (1)
			long duration = System.currentTimeMillis() - start;
			if (duration < fastest) {
				fastest = duration;
			}
		}
		return fastest;
	}

	public static void main(String[] args) {
		long n = 20_000_000;
		System.out.println("并行归纳耗时:" + test(SumComputer::wrongSum, n)); (2)
	}

public class Shop {

	//省略掉一些代码，只看关键部分

	public static void delay() { (1)
		try {
			Thread.sleep(1000L);
		} catch (Exception e) {
			throw new RuntimeException(e);
		}
	}

	private double calculatePrice(String product) { (2)
		delay();
		return random.nextDouble() * 100;
	}

	public Future<Double> getPriceAsync(String product) {
		CompletableFuture<Double> futurePrice = new CompletableFuture<>(); (3)
		new Thread(() -> futurePrice.complete(calculatePrice(product))).start(); (4)
		return futurePrice; (5)
	}

	public static void main(String[] args) throws Exception {
		Shop shop = new Shop("BestShop");
		long start = System.currentTimeMillis();
		Future<Double> futurePrice = shop.getPriceAsync("some product"); (6)
		System.out.println("调用返回,耗时:"+ (System.currentTimeMillis() - start));
		double price = futurePrice.get(); (7)
		System.out.println("价格返回,耗时"+ (System.currentTimeMillis() - start));
	}
}

public Future<Double> getPriceAsync(String product) {
	return CompletableFuture.supplyAsync(() -> calculatePrice(product));
}

public double getPrice(String product) {
	return calculatePrice(product);
}

private List<Shop> shops = Arrays.asList(
			new Shop("shop1"),
			new Shop("shop2"),
			new Shop("shop3"),
			new Shop("shop4"),
			new Shop("shop5"),
			new Shop("shop6"),
			new Shop("shop7"),
			new Shop("shop8"));

public List<String> findPrices(String product)

public List<String> findPrices(String product) {
	return shops.stream()
			.map(shop -> String.format("s% price is %.2f", shop.getName(), shop.getPrice(product)))
			.collect(Collectors.toList());
}

public static void main(String[] args) {
	PriceService priceService = new PriceService();
	long start = System.currentTimeMillis();
	System.out.println(priceService.findPrices("iPhone7"));
	System.out.println("服务耗时:" + ( System.currentTimeMillis() - start ));
}

public List<String> findPrices(String product) {
	return shops.parallelStream() (1)
			.map(shop -> String.format("s% price is %.2f", shop.getName(), shop.getPrice(product)))
			.collect(Collectors.toList());
}

public List<String> findPrices(String product) {

	List<CompletableFuture<String>> priceFuture = shops.stream()
			.map(shop -> CompletableFuture
					.supplyAsync(() -> String.format("%s price is %.2f", shop.getName(), shop.getPrice(product)))) (1)
			.collect(Collectors.toList());

	return priceFuture.stream().map(CompletableFuture::join) (2)
					.collect(Collectors.toList());

}

Executor executor = Executors.newFixedThreadPool(Math.min(shops.size(), 100)); (1)

List<CompletableFuture<String>> priceFuture = shops.stream()
		.map(shop -> CompletableFuture.supplyAsync(
				() -> String.format("%s price is %.2f", shop.getName(), shop.getPrice(product)), executor)) (2)
		.collect(Collectors.toList());

return priceFuture.stream().map(CompletableFuture::join).collect(Collectors.toList());

public enum Discount {

	NONE(0), SILVER(5), GOLD(10), PLATINUM(15), DIAMOND(20);

	private final int percentage;

	Discount(int percentage) {
		this.percentage = percentage;
	}
}

public String getPrice(String product) {
	double price = calculatePrice(product);
	Discount discount = Discount.values()[random.nextInt(Discount.values().length)];
	return String.format("%s:%.2f:%s", name, price, discount);
}

public class Quote {

	private final String shop;
	private final double price;
	private final Discount discount;

	public Quote(String shop, double price, Discount discount) {
		this.shop = shop;
		this.price = price;
		this.discount = discount;
	}

	public static Quote parse(String content) {
		String[] items = StringUtils.splitByWholeSeparatorPreserveAllTokens(content, ":");
		return new Quote(items[0], Double.parseDouble(items[1]), Discount.valueOf(items[2]));
	}
}

public class DiscountService {

	public static String applyDiscount(Quote quote) {
		return quote.getShop() + " price is " + apply(quote.getPrice(), quote.getDiscount());
	}

	private static String apply(double price, Discount discount) {
		delay(); (1)
		return NumberFormat.getInstance().format(price * (100 - discount.getPercentage()) / 100);
	}
}

public List<String> findPrices(String product) {

	return shops.stream()
			.map(shop -> shop.getPrice(product)) (1)
			.map(Quote::parse) (2)
			.map(DiscountService::applyDiscount) (3)
			.collect(Collectors.toList());
}

public List<String> findPrices(String product) {

		Executor executor = Executors.newFixedThreadPool(Math.min(shops.size(), 100));

		List<CompletableFuture<String>> priceFuture = shops.stream()
				.map(shop -> CompletableFuture.supplyAsync(() -> shop.getPrice(product), executor)) (1)
				.map(future -> future.thenApply(Quote::parse)) (2)
				.map(future -> future.thenCompose(
						quote -> CompletableFuture.supplyAsync(() -> DiscountService.applyDiscount(quote), executor))) (3)
				.collect(Collectors.toList();

		return priceFuture.stream().map(CompletableFuture::join).collect(Collectors.toList()); (4)
}

public class ExchangeService {

	public static double getRate(String source, String target) { (1)
		delay();
		return 10;
	}

	public static void delay() {
		try {
			Thread.sleep(1000L);
		} catch (Exception e) {
			throw new RuntimeException(e);
		}
	}

}

public Quote getPrice(String product) { (1)
	double price = calculatePrice(product);
	Discount discount = Discount.values()[random.nextInt(Discount.values().length)];
	return Quote.parse(String.format("%s:%.2f:%s", name, price, discount)); (2)
}

public List<String> findPrices(String product) {

	Executor executor = Executors.newFixedThreadPool(100); (1)

	List<CompletableFuture<String>> priceFuture = shops.stream()
			.map(shop -> CompletableFuture.supplyAsync(() -> shop.getPrice(product), executor).thenCombine( (2)
					CompletableFuture.supplyAsync(() -> ExchangeService.getRate("USD", "CNY"), executor), (3)
					(quote, rate) -> new Quote(quote.getShop(), quote.getPrice() * rate, quote.getDiscount()))) (4)
			.map(future -> future.thenCompose(
					quote -> CompletableFuture.supplyAsync(() -> DiscountService.applyDiscount(quote), executor)))
			.collect(Collectors.toList());

	return priceFuture.stream().map(CompletableFuture::join).collect(Collectors.toList());
}

public static void delay() {
	int delay = 500 + random.nextInt(2000);
	try {
		Thread.sleep(delay);
	} catch (Exception e) {
		throw new RuntimeException(e);
	}
}

public void findPrices(String product) {

	long start = System.currentTimeMillis();

	Executor executor = Executors.newFixedThreadPool(100);

	CompletableFuture<?>[] futures = shops.stream()
			.map(shop -> CompletableFuture.supplyAsync(() -> shop.getPrice(product), executor).thenCombine(
					CompletableFuture.supplyAsync(() -> ExchangeService.getRate("USD", "CNY"), executor),
					(quote, rate) -> new Quote(quote.getShop(), quote.getPrice() * rate, quote.getDiscount())))
			.map(future -> future.thenCompose(
					quote -> CompletableFuture.supplyAsync(() -> DiscountService.applyDiscount(quote), executor)))
			.map(future -> future.thenAccept(content ->  (1)
					System.out.println(content + " (done in " + (System.currentTimeMillis() - start )+" msecs)")))
			.toArray(size -> new CompletableFuture[size]);

}

public void findPrices(String product) {

	long start = System.currentTimeMillis();

	Executor executor = Executors.newFixedThreadPool(100);

	CompletableFuture<?>[] futures = shops.stream()
			.map(shop -> CompletableFuture.supplyAsync(() -> shop.getPrice(product), executor).thenCombine(
					CompletableFuture.supplyAsync(() -> ExchangeService.getRate("USD", "CNY"), executor),
					(quote, rate) -> new Quote(quote.getShop(), quote.getPrice() * rate, quote.getDiscount())))
			.map(future -> future.thenCompose(
					quote -> CompletableFuture.supplyAsync(() -> DiscountService.applyDiscount(quote), executor)))
			.map(future -> future.thenAccept(content ->
					System.out.println(content + " (done in " + (System.currentTimeMillis() - start )+" msecs)")))
			.toArray(size -> new CompletableFuture[size]);

	CompletableFuture.allOf(futures).thenAccept((obj) -> System.out.println("all shop return results or time out")); (1)

}

public void findPrices(String product) {

		long start = System.currentTimeMillis();

		Executor executor = Executors.newFixedThreadPool(100);

		CompletableFuture<?>[] futures = shops.stream()
				.map(shop -> CompletableFuture.supplyAsync(() -> shop.getPrice(product), executor).thenCombine(
						CompletableFuture.supplyAsync(() -> ExchangeService.getRate("USD", "CNY"), executor),
						(quote, rate) -> new Quote(quote.getShop(), quote.getPrice() * rate, quote.getDiscount())))
				.map(future -> future.thenCompose(
						quote -> CompletableFuture.supplyAsync(() -> DiscountService.applyDiscount(quote), executor)))
				.toArray(size -> new CompletableFuture[size]);

		CompletableFuture.anyOf(futures).thenAccept((content) -> System.out.println(
				"fastest shop : " + content + " (done in " + (System.currentTimeMillis() - start) + " msecs)")); (1)

}

@Configuration
public class Config {

	@Bean
	public TaskExecutor taskExecutor() {
		ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor(); (1)
		taskExecutor.setCorePoolSize(10); (2)
		taskExecutor.setMaxPoolSize(25); (3)
		taskExecutor.setQueueCapacity(10); (4)
		return taskExecutor;
	}

}

@Component
public class TestServiceImpl implements TestService {

	@Autowired
	private TaskExecutor taskExecutor; (1)

	public void handle() {
		for (int i = 0; i < 100; i++) {
			int index = i;
			taskExecutor.execute(() -> System.out.println(index)); (2)
		}
	}
}

@Async
void doSomething(String s) {
    // this will be executed asynchronously
}

@Async
Future<String> returnSomething(int i) {
    // this will be executed asynchronously
}

@Async("otherExecutor") (1)
void doSomething(String s) {
    // this will be executed asynchronously by "otherExecutor"
}

@GetMapping("/greeting")
public SimpleResponse<String> greeting(@AuthenticationPrincipal String user) throws Exception { (1)
	return new SimpleResponse<>("hello "+user);
}

@Component (1)
public class DemoConfigProvider implements AuthorizeConfigProvider { (2)

	/* (non-Javadoc)
	 * @see com.imooc.security.core.authorize.AuthorizeConfigProvider#config(org.springframework.security.config.annotation.web.configurers.ExpressionUrlAuthorizationConfigurer.ExpressionInterceptUrlRegistry)
	 */
	@Override
	public boolean config(ExpressionUrlAuthorizationConfigurer<HttpSecurity>.ExpressionInterceptUrlRegistry config) {
        config.antMatchers(HttpMethod.GET, "/api/**").permitAll() (3)
              .mvcMatchers(HttpMethod.POST, "/user/{id}").permitAll() (4)
              .regexMatchers(HttpMethod.GET, "/^[0-9]*$").permitAll(); (5)
        return false; (6)
    }

}

@Component("rbacService") (1)
@Primary (2)
public class DemoRbacService implements RbacService { (3)

	/* (non-Javadoc)
	 * @see com.zkh360.zaf.security.client.authorize.RbacService#hasPermission(javax.servlet.http.HttpServletRequest, org.springframework.security.core.Authentication)
	 */
	@Override
	public boolean hasPermission(HttpServletRequest request, Authentication authentication) { (4)
		boolean result = check(request, authentication) (5)
		return result; (6)
	}

}

<dependency>
	<groupId>com.zkh360.security</groupId>
	<artifactId>zaf-security-client</artifactId>
	<version>1.1.0-RELEASE</version>
</dependency>

KmsUtils utils = new KmsUtils(clientId, clientSecret); (1)
String ciphertext = utils.encrypt("13011056600"); (2)
String plaintext = utils.decrypt(ciphertext); (3)